package com.xxwu.messagequeue.common;

import lombok.Data;

/**
 * 消费者对象
 */
@Data
public class ConsumerEnv {
    private String ConsumerTag;
    private String queueName;
    private boolean autoAck;
    // 使用这个回调函数，对收到的消息进行处理
    private Consumer consumer;

    public ConsumerEnv(String consumerTag, String queueName, boolean autoAck, Consumer consumer) {
        ConsumerTag = consumerTag;
        this.queueName = queueName;
        this.autoAck = autoAck;
        this.consumer = consumer;
    }
}
